package com.myrice.jms;

import java.nio.ByteBuffer;

import com.myrice.jms.impl.DefaultMessage;

public interface MessageFactory {

	MsgRequest create(MsgSession session, ByteBuffer msg);

	ByteBuffer encode(MsgSession session, byte type, int mode, ByteBuffer data);

	void recycle(DefaultMessage message);

}
